package cn.tedu.cqhotel.service.impl;

import cn.tedu.cqhotel.ex.ServiceCode;
import cn.tedu.cqhotel.ex.ServiceException;
import cn.tedu.cqhotel.mapper.UserMapper;
import cn.tedu.cqhotel.pojo.dto.UserAddNewDTO;
import cn.tedu.cqhotel.pojo.dto.UserUpdateDTO;
import cn.tedu.cqhotel.pojo.entity.User;
import cn.tedu.cqhotel.pojo.vo.UserListItemVO;
import cn.tedu.cqhotel.pojo.vo.UserStandardVO;
import cn.tedu.cqhotel.service.IUserService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.List;

/**
 * 处理用户列表的实现类
 *
 * @author java@tedu.cn
 * @version 0.0.1
 */
@Slf4j
@Service
public class UserServiceImpl implements IUserService {

    @Autowired
    private UserMapper userMapper;


    public UserServiceImpl() {
        log.info("创建业务对象：UserServiceImpl");
    }

    @Override
    public void addNew(UserAddNewDTO userAddNewDTO) {
        log.debug("开始处理【添加用户】的业务，参数：{}", userAddNewDTO);

        // 创建用户列表对象，用于插入到数据表
        User user = new User();
        BeanUtils.copyProperties(userAddNewDTO, user);

        // 插入数据
        log.debug("即将向数据库中插入数据：{}", user);
        int rows = userMapper.insert(user);
        if (rows != 1) {
            String message = "添加用户失败，服务器忙，请稍后再次尝试！";
            log.warn(message);
            throw new ServiceException(ServiceCode.ERR_INSERT, message);
        }
    }

    @Override
    public void deleteById(Long id) {
        log.debug("开始处理【删除用户】的业务，参数：{}", id);
        // 调用Mapper对象的getDetailsById()方法执行查询
        UserStandardVO queryResult = userMapper.getStandardById(id);
        // 判断查询结果是否为null
        if (queryResult == null) {
            // 是：此id对应的数据不存在，则抛出异常(ERR_NOT_FOUND)
            String message = "删除用户信息失败，尝试删除的数据不存在！";
            log.warn(message);
            throw new ServiceException(ServiceCode.ERR_NOT_FOUND, message);
        }

        // 调用Mapper对象的deleteById()执行删除，并获取返回值
        int rows = userMapper.deleteById(id);
        // 判断以上返回值是否不为1
        if (rows != 1) {
            // 是：抛出异常(ERR_DELETE)
            String message = "删除用户信息失败，服务器忙，请稍后再次尝试！";
            log.warn(message);
            throw new ServiceException(ServiceCode.ERR_DELETE, message);
        }
    }

    @Override
    public void updateById(Long id, UserUpdateDTO userUpdateDTO) {
        log.debug("开始处理【修改用户信息】的业务，参数：{}", id);
        // 调用Mapper对象的getDetailsById()方法执行查询
        UserStandardVO queryResult = userMapper.getStandardById(id);
        // 判断查询结果是否为null
        if (queryResult == null) {
            // 是：此id对应的数据不存在，则抛出异常(ERR_NOT_FOUND)
            String message = "修改用户信息失败，尝试访问的数据不存在！";
            log.warn(message);
            throw new ServiceException(ServiceCode.ERR_NOT_FOUND, message);
        }

        User user = new User();
        BeanUtils.copyProperties(userUpdateDTO, user);
        user.setId(id);

        // 修改数据
        log.debug("即将修改数据：{}", user);
        int rows = userMapper.updateById(user);
        if (rows != 1) {
            String message = "修改用户信息失败，服务器忙，请稍后再次尝试！";
            log.warn(message);
            throw new ServiceException(ServiceCode.ERR_UPDATE, message);
        }
    }

    @Override
    public UserStandardVO getStandardById(Long userId) {
        log.debug("开始处理【根据userId查询用户信息】的业务");
        UserStandardVO user = userMapper.getStandardById(userId);
        if (user == null) {
            // 是：此userId对应的数据不存在，则抛出异常(ERR_NOT_FOUND)
            String message = "获取用户信息失败，尝试访问的数据不存在！";
            log.warn(message);
            throw new ServiceException(ServiceCode.ERR_NOT_FOUND, message);
        }
        return user;
    }

    @Override
    public List<UserListItemVO> listByName(String name) {
        log.debug("开始处理【根据name查询用户信息】的业务");
        return userMapper.listByName(name);
    }

    @Override
    public List<UserListItemVO> list() {
        log.debug("开始处理【查询员工信息列表】的业务");
        return userMapper.list();
    }
}
